package com.hmy.canal.kafka;

public class KafkaProperty {

    public static String topic = "local-mysql-change-topic";
    public static Integer partition = 0;

    // 必须指定groupId
    // 否则提示Attempt to join group failed due to fatal error: The configured groupId is invalid
    public static String groupId = "g4";
    public static String servers = "127.0.0.1:9092";
    public static String zkServers = "127.0.0.1:2181";

}
